package cn.dqy.gotanserver.dto;

import io.netty.channel.socket.nio.NioSocketChannel;

import java.util.ArrayDeque;
import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;

public class ChannelInfo {
    NioSocketChannel nioSocketChannel;
    String pullStreamPath;
    Queue<String> picQueue;

    public ChannelInfo(NioSocketChannel channel,String pullStreamPath){
        this.nioSocketChannel=channel;
        this.pullStreamPath=pullStreamPath;
        this.picQueue=new LinkedBlockingQueue<>();
    }

    public Queue<String> getPicQueue() {
        return picQueue;
    }

    public void setPicQueue(Queue<String> picQueue) {
        this.picQueue = picQueue;
    }

    public NioSocketChannel getNioSocketChannel() {
        return nioSocketChannel;
    }

    public void setNioSocketChannel(NioSocketChannel nioSocketChannel) {
        this.nioSocketChannel = nioSocketChannel;
    }

    public String getPullStreamPath() {
        return pullStreamPath;
    }

    public void setPullStreamPath(String pullStreamPath) {
        this.pullStreamPath = pullStreamPath;
    }
}
